//链接数据库，交互
const mysql = require('mysql');

module.exports = (sql) => {

    //1.创建连接对象
    const connection = mysql.createConnection({
        host:'localhost',
        port:3306,
        user:'root',
        password:'root',
        database:'user_list'  //数据库名字
    })
    
    //2.链接数据库
    connection.connect((error) => {
        if(error){
            console.log("数据库连接失败")
        }else{
            console.log("数据库连接成功")
        }
    })

    //promise 容器 --->  异步的代码,未来才会发生的事
    //进行中  已成功  已失败 三种状态   
    //进行中 ----> 已成功  resolve()  
    //进行中-----> 已失败 reject()
    //then((res) => {成功的数据},(error) => {错误信息})
    return new Promise((resolve,reject) => {
        // 3.和数据库进行交互(异步的)  query(sql语句,[传递的参数],callback)  
        connection.query(sql,(error,data) => {
            if(error){
                reject(error)
            }else{
                resolve(data)
            }
            //4.结束链接
            connection.end();
        }) 
    })
}